package demo.common;

import demo.mqserver.core.BasicProperties;

import java.io.IOException;


//只是一个单纯的函数式接口（回调函数），收到消息后要处理消息时调用的方法
@FunctionalInterface
public interface Consumer {

    //服务器每次收到消息之后来调用
    //把消息推送给对应的消费者
    void handleDelivery(String consumerTag, BasicProperties basicProperties, byte[] body) throws MqException, IOException;
}
